d80ee71621b0308cd16d2f43bc098c2446d4dda3,clients/unshaded/src/test/java/tachyon/client/file/FileOutStreamTest.java,FileOutStreamTest,closeTest,#,193

Before Change


      Assert.assertTrue(mTachyonOutStreamMap.get(streamIndex).isClosed());
    }
    Mockito.verify(mWorkerClient, Mockito.times(1)).persistFile(Mockito.eq(FILE_ID),
        Mockito.anyLong(), Mockito.anyString());
    Mockito.verify(mFileSystemMasterClient, Mockito.times(1)).completeFile(FILE_ID);
    Mockito.verify(mBlockStoreContext, Mockito.timeout(1)).acquireWorkerClient();
    Mockito.verify(mBlockStoreContext, Mockito.timeout(1)).releaseWorkerClient(mWorkerClient);

After Change


   */
  @Test
  public void closeTest() throws Exception {
    Mockito.when(mUnderFileSystem.rename(Mockito.anyString(), Mockito.anyString()))
        .thenReturn(true);
    mTestStream.write(BufferUtils.getIncreasingByteArray((int) (BLOCK_LENGTH * 1.5)));
    mTestStream.close();
    for (long streamIndex = 0; streamIndex < 2; streamIndex ++) {
      Assert.assertFalse(mTachyonOutStreamMap.get(streamIndex).isCanceled());
      Assert.assertTrue(mTachyonOutStreamMap.get(streamIndex).isClosed());
    }
    Mockito.verify(mFileSystemMasterClient, Mockito.times(1)).completeFile(Mockito.eq(FILE_ID),
        Mockito.any(CompleteFileOptions.class));
  }

  /**